package com.atguigu.gmall.realtime.bean;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

/**
 * @Description: 配置表中的实体类,用于(FlinkCDC处理表变化) 自定义反序列化器
 * @Author: tiancy
 * @Create: 2021/11/26
 */
@Data
public class TableProcess {
    //动态分流Sink常量   改为小写和脚本一致
    public static final String SINK_TYPE_HBASE = "hbase";
    public static final String SINK_TYPE_KAFKA = "kafka";
    public static final String SINK_TYPE_CK = "clickhouse";
    //来源表,就是业务表中的表名
    String sourceTable;
    //操作类型 insert,update,delete
    String operateType;
    //输出类型 hbase kafka
    String sinkType;
    //输出表(数据最终写出的位置,是维度就进入HBase,是事实就进入Kafka)
    String sinkTable;
    //输出字段,当前表中存在的字段
    String sinkColumns;
    //主键字段
    String sinkPk;
    //建表扩展(建表时指定使用什么引擎、使用的编码格式.)
    String sinkExtend;
}
